from celery import Celery

# 进行Celery允许配置， 需要告知celery django的配置文件在哪里
# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'

# 创建celery对象， 参数 main 是任务路径(习惯设置为celery 路径， 确保celery唯一就行)
app = Celery('celery_tasks')
# 加载配置文件， 实现broker设置
app.config_from_object('celery_tasks.config')
# 自动加载任务， 让celery实例自动加载任务， 列表任务， 需要指明任务路径
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email', 'celery_tasks.html'])